package com.springboot.jeesite.common.queue.jvm;

import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;

/**
 * 消费秒杀队列
 * 创建者 xxx
 * 创建时间	2018年4月3日
 */
public class TaskRunner implements ApplicationRunner {
    @Override
    public void run(ApplicationArguments var) throws Exception {
        //while (true) 一定不要这样写
        // @Component 继承ApplicationRunner 启动时候会死循环的
        //导致外置tomcat启动不了，查了一天啊。。。。
        //实际应用过程中要用定时器定时去扫
        //while (true) {
        if (SeckillQueue.getMailQueue().size() > 0) {
            //进程内队列
            String kill = SeckillQueue.getMailQueue().consume();
            if (kill != null) {
                System.out.println(kill);
            }
        }
    }
}